# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.oss.oss_tmp_center_detention_detail import oss__oss_tmp_center_detention_detail


oss__center_detention_center_cnt = BashOperator(
    task_id='oss__center_detention_center_cnt',
    email=['guoruiling@jtexpress.com','yl_bigdata@yl-scm.com'],
    pool='unlimited_pool',
    bash_command='jms/oss/export_center_detention_center_cnt/execute.sh',
    execution_timeout=timedelta(minutes=30)
)

oss__center_detention_center_cnt << [ oss__oss_tmp_center_detention_detail ]
